package com.hu._01_hello_world;

import com.hu.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

//消息发送者
public class Send {

    //队列的名字
    public static final String NAME_QUEUE_HELLOWORLD = "name_queue_helloworld";

    public static void main(String[] args) throws Exception {
        //通过连接工具创建链接对象
        Connection connection = ConnectionUtil.getConnection();

        //连接对象 创建通道
        Channel channel = connection.createChannel();

        /** 创建队列
         *  参数：
         *  队列名，持久化，独占链接，队列用完删除，扩展参数
         */
        channel.queueDeclare(NAME_QUEUE_HELLOWORLD,true,false,false,null);

        //使用默认的交换机 - 不创建交换机就默认了

        /*
        * 发送消息:  (通道) basicPublish
         * */
        //消息
        String message = "hello a hello";
        /**参数
         * 交换机(默认 即"")    队列名(routingkey)    额外的属性参数     消息内容(  byte[]   )
         */
        channel.basicPublish("",NAME_QUEUE_HELLOWORLD,null,message.getBytes());
        System.out.println("消息发送完毕："+message);
    }

}